DRS任务同步源端写入数据到DWS数据仓库。根据任务的配置，DRS任务会自行创建目标表，表结构与源表一致。
通过数据入库DWS数据仓库时间减去源数据库生产数据的时间算出数据的迁移时延


///任务全量迁移完成后，给目标表增加dws_time字段，主要记录后续增量迁移的数据落入DWS仓库的时间
alter table mysql_targer add dws_time timestamp(0) with time zone DEFAULT (now())::timestamp(0) without time zone NOT NULL;

///update触发器调用的函数，主要作用是更新增量（增删改）数据的dws_time字段。
CREATE OR REPLACE FUNCTION tri_update_func() RETURNS TRIGGER AS
           $$
           DECLARE
           BEGIN
                 new.dws_time=CURRENT_TIMESTAMP;
                 return new;
           END
           $$ LANGUAGE PLPGSQL;
           
///调用update触发函数创建触发器，给目标表添加触发器 ,以mysql_targer目标表为例
CREATE TRIGGER update_trigger
           BEFORE UPDATE ON mysql_targer   
           FOR EACH ROW
           EXECUTE PROCEDURE tri_update_func();
		   
		   
///数据入库DWS数据仓库时间减去源数据库生产数据的时间得出平均值，求出新增或者修改的数据增量迁移后的平均时延
///dws_time字段代表数据录入DWS仓库的时间（数据插入或者修改该字段都会改变）
///date_time代表从源端迁移过来的时间字段（源端数据插入或者修改）
///mysql_targer代表DWS仓库中的目标表
select avg(t) from (select dws_time-date_time as t from mysql_targer where id>=1 and id<=100000);


